package com.zf.rabbitmq.consumer.listener.alternate;

import org.springframework.amqp.core.Message;
import org.springframework.amqp.rabbit.annotation.RabbitListener;
import org.springframework.stereotype.Component;

/**
 * 消费备份交换机绑定的队列和正常队列
 */
@Component
public class AlternateConsumer {

    /**
     * 消费备份交换机绑定的队列，其中的消息是无法被交换机路由的消息，由备份交换机发送到了该队列中
     */
    @RabbitListener(queues = {"test_alter_alternate_queue"})
    public void consumeAlterQueue(Message message) {
        System.out.printf("无法路由消息：%s\n", new String(message.getBody()));
    }

    /**
     * 消费正常队列，其中的消息是被正常路由的消息
     */
    @RabbitListener(queues = {"test_alter_normal_queue"})
    public void consumeNormalQueue(Message message) {
        System.out.printf("正常路由消息：%s\n", new String(message.getBody()));
    }

}
